package chenxu.test.hbase.storm;

import java.io.IOException;
import java.io.Serializable;

import javax.jms.JMSException;

import org.apache.hadoop.hbase.client.Result;

import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.tuple.Values;


public interface HbaseTupleProducer extends Serializable{

	/**
	 * 
	 * @param next
	 * @return
	 * @throws JMSException
	 */
	Values toTuple(Result next) throws IOException;
	
	/**
	 * Declare the output fields produced by this JmsTupleProducer.
	 * @param declarer The OuputFieldsDeclarer for the spout.
	 */
	void declareOutputFields(OutputFieldsDeclarer declarer);
}